package cn.blnp.net.flowable.consumer;

import lombok.extern.slf4j.Slf4j;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.Processor;
import org.springframework.stereotype.Component;

/**
 * <h3></h3>
 *
 * @author <a href="mailto:blnp.yibin@qq.com">lyb</a>
 * @version 1.0
 * @since 2025/5/14 10:59
 */
@Slf4j
@Component
public class ConProcessor implements Processor {
    @Override
    public void process(Exchange exchange) throws Exception {
        Message m = exchange.getIn();
        log.warn("消费取得数据：{}",m.getBody());
        log.warn("消费数据请求头：{}",m.getHeaders());
    }
}
